package red.ouo.distributedtools.redis.message.config;

import red.ouo.distributedtools.redis.message.core.RedisMessageCore;

import java.util.concurrent.ExecutorService;

public interface MessageQueueConfigInterface {
    MessageQueueConfigInterface registerQueue(String queueName);

    /**
     * 如需自定义消息队列前缀请确保运行在注册消息队列前
     *
     * @param queuePrefix 前缀 默认 KELE_QUEUE_
     * @return
     */
    default MessageQueueConfigInterface queuePrefix(String queuePrefix) {
        RedisMessageCore.queuePrefix = queuePrefix;
        return MessageQueueConfigInterface.this;
    }

    MessageQueueConfigInterface registerQueue(String queueName, ExecutorService executorService);
}
